import org.apache.spark.sql.SparkSession

object Hello {
  def main(args: Array[String]): Unit = {

    // 一个类就是一个应用！  面试的时候，就被问到这个问题，spark中的一个application是什么？
    val session: SparkSession = SparkSession.builder().master("").appName("").getOrCreate()

    // 这个地方我们的Sparksession的构造代码就写完了

    // spark  -- spark standalone集群
    // spark  --  spark运算程序启动  -->   driver  executor等各进程的启动

    import session.implicits._

    session.read.textFile("").map(s=>XLei.hello(s))

    session.sql(
      """
        |
        |select sex,avg(age) from tmp
        |
      """.stripMargin)

  }

}

object XLei{

  def hello(s:String) = {
    s.toUpperCase()
  }
}
